org.springframework.web.context.request.async

Class WebAsyncManager

java.lang.Object

org.springframework.web.context.request.async.WebAsyncManager

public final class WebAsyncManager
extends java.lang.Object

The central class for managing asynchronous request processing, mainly intended as an SPI and not typically used directly by application classes.

An async scenario starts with request processing as usual in a thread (T1). Concurrent request handling can be initiated by calling startCallableProcessing or startDeferredResultProcessing, both of which produce a result in a separate thread (T2). The result is saved and the request dispatched to the container, to resume processing with the saved result in a third thread (T3). Within the dispatched thread (T3), the saved result can be accessed via getConcurrentResult() or its presence detected via hasConcurrentResult().

Since:

3.2

Author:

Rossen Stoyanchev

See Also:

AsyncWebRequestInterceptor, AsyncHandlerInterceptor, OncePerRequestFilter.shouldNotFilterAsyncDispatch(), OncePerRequestFilter.isAsyncDispatch(HttpServletRequest)

Field Summary

Fields

Modifier and Type	Field and Description
private AsyncWebRequest	asyncWebRequest
private java.util.Map<java.lang.Object,CallableProcessingInterceptor>	callableInterceptors
private java.lang.Object	concurrentResult
private java.lang.Object[]	concurrentResultContext
private java.util.Map<java.lang.Object,DeferredResultProcessingInterceptor>	deferredResultInterceptors
private static Log	logger
private static java.lang.Object	RESULT_NONE
private AsyncTaskExecutor	taskExecutor
private static CallableProcessingInterceptor	timeoutCallableInterceptor
private static DeferredResultProcessingInterceptor	timeoutDeferredResultInterceptor
private static UrlPathHelper	urlPathHelper

Constructor Summary

Constructors

Constructor and Description
WebAsyncManager() Package-private constructor.

Method Summary

Modifier and Type	Method and Description
void	clearConcurrentResult() Clear concurrentResult and concurrentResultContext.
CallableProcessingInterceptor	getCallableInterceptor(java.lang.Object key) Get the CallableProcessingInterceptor registered under the given key.
java.lang.Object	getConcurrentResult() Provides access to the result from concurrent handling.
java.lang.Object[]	getConcurrentResultContext() Provides access to additional processing context saved at the start of concurrent handling.
DeferredResultProcessingInterceptor	getDeferredResultInterceptor(java.lang.Object key) Get the DeferredResultProcessingInterceptor registered under the given key.
boolean	hasConcurrentResult() Whether a result value exists as a result of concurrent handling.
boolean	isConcurrentHandlingStarted() Whether the selected handler for the current request chose to handle the request asynchronously.
void	registerCallableInterceptor(java.lang.Object key, CallableProcessingInterceptor interceptor) Register a CallableProcessingInterceptor under the given key.
void	registerCallableInterceptors(CallableProcessingInterceptor... interceptors) Register a CallableProcessingInterceptor without a key.
void	registerDeferredResultInterceptor(java.lang.Object key, DeferredResultProcessingInterceptor interceptor) Register a DeferredResultProcessingInterceptor under the given key.
void	registerDeferredResultInterceptors(DeferredResultProcessingInterceptor... interceptors) Register one or more DeferredResultProcessingInterceptors without a specified key.
void	setAsyncWebRequest(AsyncWebRequest asyncWebRequest) Configure the AsyncWebRequest to use.
private void	setConcurrentResultAndDispatch(java.lang.Object result)
void	setTaskExecutor(AsyncTaskExecutor taskExecutor) Configure an AsyncTaskExecutor for use with concurrent processing via startCallableProcessing(Callable, Object...).
private void	startAsyncProcessing(java.lang.Object[] processingContext)
void	startCallableProcessing(java.util.concurrent.Callable<?> callable, java.lang.Object... processingContext) Start concurrent request processing and execute the given task with an AsyncTaskExecutor.
void	startCallableProcessing(WebAsyncTask<?> webAsyncTask, java.lang.Object... processingContext) Use the given WebAsyncTask to configure the task executor as well as the timeout value of the AsyncWebRequest before delegating to startCallableProcessing(Callable, Object...).
void	startDeferredResultProcessing(DeferredResult<?> deferredResult, java.lang.Object... processingContext) Start concurrent request processing and initialize the given DeferredResult with a DeferredResult.DeferredResultHandler that saves the result and dispatches the request to resume processing of that result.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

RESULT_NONE

private static final java.lang.Object RESULT_NONE

logger

private static final Log logger

urlPathHelper

private static final UrlPathHelper urlPathHelper

timeoutCallableInterceptor

private static final CallableProcessingInterceptor timeoutCallableInterceptor

timeoutDeferredResultInterceptor

private static final DeferredResultProcessingInterceptor timeoutDeferredResultInterceptor

asyncWebRequest

private AsyncWebRequest asyncWebRequest

taskExecutor

private AsyncTaskExecutor taskExecutor

concurrentResult

private java.lang.Object concurrentResult

concurrentResultContext

private java.lang.Object[] concurrentResultContext

callableInterceptors

private final java.util.Map<java.lang.Object,CallableProcessingInterceptor> callableInterceptors

deferredResultInterceptors

private final java.util.Map<java.lang.Object,DeferredResultProcessingInterceptor> deferredResultInterceptors

Constructor Detail

WebAsyncManager

WebAsyncManager()

Package-private constructor.

See Also:

WebAsyncUtils#getAsyncManager(javax.servlet.ServletRequest), WebAsyncUtils#getAsyncManager(org.springframework.web.context.request.WebRequest)

Method Detail

setAsyncWebRequest

public void setAsyncWebRequest(AsyncWebRequest asyncWebRequest)

Configure the AsyncWebRequest to use. This property may be set more than once during a single request to accurately reflect the current state of the request (e.g. following a forward, request/response wrapping, etc). However, it should not be set while concurrent handling is in progress, i.e. while isConcurrentHandlingStarted() is true.

Parameters:

asyncWebRequest - the web request to use

setTaskExecutor

public void setTaskExecutor(AsyncTaskExecutor taskExecutor)

Configure an AsyncTaskExecutor for use with concurrent processing via startCallableProcessing(Callable, Object...).

By default a SimpleAsyncTaskExecutor instance is used.

isConcurrentHandlingStarted

public boolean isConcurrentHandlingStarted()

Whether the selected handler for the current request chose to handle the request asynchronously. A return value of "true" indicates concurrent handling is under way and the response will remain open. A return value of "false" means concurrent handling was either not started or possibly that it has completed and the request was dispatched for further processing of the concurrent result.

hasConcurrentResult

public boolean hasConcurrentResult()

Whether a result value exists as a result of concurrent handling.

getConcurrentResult

public java.lang.Object getConcurrentResult()

Provides access to the result from concurrent handling.

Returns:

an Object, possibly an Exception or Throwable if concurrent handling raised one.

See Also:

clearConcurrentResult()

getConcurrentResultContext

public java.lang.Object[] getConcurrentResultContext()

Provides access to additional processing context saved at the start of concurrent handling.

See Also:

clearConcurrentResult()

getCallableInterceptor

public CallableProcessingInterceptor getCallableInterceptor(java.lang.Object key)

Get the CallableProcessingInterceptor registered under the given key.

Parameters:

key - the key

Returns:

the interceptor registered under that key or null

getDeferredResultInterceptor

public DeferredResultProcessingInterceptor getDeferredResultInterceptor(java.lang.Object key)

Get the DeferredResultProcessingInterceptor registered under the given key.

Parameters:

key - the key

Returns:

the interceptor registered under that key or null

registerCallableInterceptor

public void registerCallableInterceptor(java.lang.Object key,
                                        CallableProcessingInterceptor interceptor)

Register a CallableProcessingInterceptor under the given key.

Parameters:

key - the key

interceptor - the interceptor to register

registerCallableInterceptors

public void registerCallableInterceptors(CallableProcessingInterceptor... interceptors)

Register a CallableProcessingInterceptor without a key. The key is derived from the class name and hashcode.

Parameters:

interceptors - one or more interceptors to register

registerDeferredResultInterceptor

public void registerDeferredResultInterceptor(java.lang.Object key,
                                              DeferredResultProcessingInterceptor interceptor)

Register a DeferredResultProcessingInterceptor under the given key.

Parameters:

key - the key

interceptor - the interceptor to register

registerDeferredResultInterceptors

public void registerDeferredResultInterceptors(DeferredResultProcessingInterceptor... interceptors)

Register one or more DeferredResultProcessingInterceptors without a specified key. The default key is derived from the interceptor class name and hash code.

Parameters:

interceptors - one or more interceptors to register

clearConcurrentResult

public void clearConcurrentResult()

Clear concurrentResult and concurrentResultContext.

startCallableProcessing

public void startCallableProcessing(java.util.concurrent.Callable<?> callable,
                                    java.lang.Object... processingContext)
                             throws java.lang.Exception

Start concurrent request processing and execute the given task with an AsyncTaskExecutor. The result from the task execution is saved and the request dispatched in order to resume processing of that result. If the task raises an Exception then the saved result will be the raised Exception.

Parameters:

callable - a unit of work to be executed asynchronously

processingContext - additional context to save that can be accessed via getConcurrentResultContext()

Throws:

java.lang.Exception - if concurrent processing failed to start

See Also:

getConcurrentResult(), getConcurrentResultContext()

startCallableProcessing

public void startCallableProcessing(WebAsyncTask<?> webAsyncTask,
                                    java.lang.Object... processingContext)
                             throws java.lang.Exception

Use the given WebAsyncTask to configure the task executor as well as the timeout value of the AsyncWebRequest before delegating to startCallableProcessing(Callable, Object...).

Parameters:

webAsyncTask - a WebAsyncTask containing the target Callable

processingContext - additional context to save that can be accessed via getConcurrentResultContext()

Throws:

java.lang.Exception - if concurrent processing failed to start

setConcurrentResultAndDispatch

private void setConcurrentResultAndDispatch(java.lang.Object result)

startDeferredResultProcessing

public void startDeferredResultProcessing(DeferredResult<?> deferredResult,
                                          java.lang.Object... processingContext)
                                   throws java.lang.Exception

Start concurrent request processing and initialize the given DeferredResult with a DeferredResult.DeferredResultHandler that saves the result and dispatches the request to resume processing of that result. The AsyncWebRequest is also updated with a completion handler that expires the DeferredResult and a timeout handler assuming the DeferredResult has a default timeout result.

Parameters:

deferredResult - the DeferredResult instance to initialize

processingContext - additional context to save that can be accessed via getConcurrentResultContext()

Throws:

java.lang.Exception - if concurrent processing failed to start

See Also:

getConcurrentResult(), getConcurrentResultContext()

startAsyncProcessing

private void startAsyncProcessing(java.lang.Object[] processingContext)